package bigdata.backend.monitor.binlog;

import bigdata.backend.monitor.binlog.service.KafkaMonitorService;
import bigdata.backend.monitor.utils.KafkaProgressUtils;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

@SpringBootTest
public class TestKafkaMonitorService {

    @Autowired
    private KafkaMonitorService kafkaMonitorService;

    @Test
    public void test01() {
        KafkaProgressUtils.TopicProgressInfo binlogTopicProgress = kafkaMonitorService.getBinlogTopicProgress();
        System.out.println(binlogTopicProgress.toString());

        KafkaProgressUtils.TopicProgressInfo violationTopicProgress = kafkaMonitorService.getViolationTopicProgress();
        System.out.println(violationTopicProgress.toString());
    }

}
